package cn.joinhealth.effect.spark;

import cn.joinhealth.effect.spark.service.PatientStatisticsService;
import org.apache.spark.sql.SparkSession;

/**
 * @author yuan
 * @description spark测试
 * @date 2022/3/4 17:52
 */
public class Application {

    public static void main(String[] args) {
        SparkSession sparkSession = SparkSession.builder()
                .appName("spark-test")
                .master("local[*]")
                .enableHiveSupport()
                .getOrCreate();

        PatientStatisticsService.countServiceTimes(sparkSession);
        sparkSession.stop();
    }
}
